package com.navinfo.tripanalysis.offline.service;

import com.navinfo.tripanalysis.common.arithmetic.common.EngineAggregatedData;
import org.apache.spark.api.java.JavaPairRDD;
import org.apache.spark.api.java.JavaSparkContext;
import org.apache.spark.sql.SparkSession;

import java.util.List;

/**
 * 保存行程发动机数据服务
 * @author 刘俊
 */
public interface SaveTripEngineDataService {

     void save(SparkSession spark, JavaSparkContext jsc, JavaPairRDD<Long, List<EngineAggregatedData>> pairRDD, long d);
}
